//package com.canal.mq.config;
//
//import org.springframework.beans.factory.annotation.Value;
//import org.springframework.context.annotation.Configuration;
//
//@Configuration
//public class ConsumerConfig {
//
//    @Value("${rocketmq.consumer.groupId}")
//    private String groupId;
//    @Value("${rocketmq.consumer.topic}")
//    private String topic;
//    @Value("${rocketmq.consumer.consumeMessageBatchMaxSize}")
//    private int consumeMessageBatchMaxSize;
//
//
//    public String getTopic() {
//        return topic;
//    }
//
//    public void setTopic(String topic) {
//        this.topic = topic;
//    }
//
//    public String getGroupId() {
//        return groupId;
//    }
//
//    public void setGroupId(String groupId) {
//        this.groupId = groupId;
//    }
//
//    public int getConsumeMessageBatchMaxSize() {
//        return consumeMessageBatchMaxSize;
//    }
//
//    public void setConsumeMessageBatchMaxSize(int consumeMessageBatchMaxSize) {
//        this.consumeMessageBatchMaxSize = consumeMessageBatchMaxSize;
//    }
//}
